package com.fyyg.redis.redistimer;

public class RedisTimer {
	
	
	public  void processUserEvent() {
//		if(RedisConfig.flag_eventuser_isrunning == false){
//			return;
//		}
//		RedisConfig.flag_eventuser_isrunning = false;
//		String eventKey = "";
//    	ShardedJedis jedis = null;
//		User user = null;
//		try {
//			jedis=RedisBase.getInstance().getResource();
//			while(true){
//				eventKey = RedisUtil.rpopEventList(jedis,RedisConfig.key_event_user_list);
//				if(null == eventKey){
//					break;
//				}
//				String thekey = RedisConfig.KEY_LOGIN_USER+":"+eventKey;
//				String theIp = RedisConfig.KEY_LOGIN_USER_IP+":"+eventKey;
//				if(jedis.exists(thekey)){
//					
//					System.out.println(thekey+"-----------"+theIp);
					
//					user=new User();
//					String uJson = jedis.get(thekey);
//					String reqIp = jedis.get(theIp);
//					if(! StringUtils.isBlank(uJson)){
//						user= new ObjectMapper().readValue(uJson, User.class);
//						try {
//							userService.updateLoginRecord(user.getId(),reqIp);
//							userService.insertLoginLogByredis(user.getId(),user.getUserName(), reqIp);
//							jedis.rpop(RedisConfig.key_event_user_list); //从list的尾部删除元素，并返回删除元素：
//							jedis.del(theIp); //删除缓存中的Ip
//						} catch (RuntimeException e) {
//							RedisUtil.lpushEventList(jedis,RedisConfig.key_event_user_list,eventKey);
//							e.printStackTrace();
//						}
//					}
//				}else{
//					continue;
//				}
//			}
//			
//		} catch (Exception e) {
//			e.printStackTrace();
//			RedisBase.getInstance().returnBrokenResource(jedis);
//		}finally{
//			RedisBase.getInstance().returnResource(jedis);
//		}
//		RedisConfig.flag_eventuser_isrunning = true;
	}
	
}
